package com.czk.java;

import org.apache.spark.rdd.RDD;
import org.apache.spark.sql.SparkSession;
import scala.collection.Seq;

import java.util.Arrays;
import java.util.List;

/**
 * @Author:ChenZhangKun
 * @Date: 2021/12/14 15:03
 */
public class JavaSparkRead {
    public static void main(String[] args) {
        // 创建sparkSession
        SparkSession sparkSession = SparkSession.builder().appName("java").master("local[*]").getOrCreate();
        sparkSession.sparkContext().setLogLevel("WARN");
        List<Person> people = Arrays.asList(new Person("czk", 20), new Person("nzq", 21));

    }
}
class Person{
    private String name;
    private int age;

    public Person(String name, int age) {
        this.name = name;
        this.age = age;
    }
}
